/*
package com.dubbo1.lib.mq;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

@Slf4j
@Service
@RocketMQMessageListener(topic = "rocketmq3", consumerGroup = "my-group3")
class RocketMqReceive3 implements RocketMQListener<Object> {

    @Override
    public void onMessage(Object message) {
        log.info("received rocketmq3  message: {}", JSON.toJSONString(message));
    }
}*/
